1bb6ee06c97662b87dc44c3e6bf9ce7841084b8a,protocols/valve/source/query/src/main/java/com/ibasco/agql/protocols/valve/source/query/handlers/SourceRconPacketAssembler.java,SourceRconPacketAssembler,channelRead0,#ChannelHandlerContext#ByteBuf#,82

Before Change



                    responseQueue.add(new RconSplitPacketBuilder(requestId, bodySize, responseHeader, sender, body));

                    log.debug("Found a possible split packet! Readable Bytes : {}, Byte #1: {}, Byte #2: {} \n {}", msg.readableBytes(), msg.getByte(packetSize - 2), msg.getByte(packetSize - 1), hexDump);
                }
            }
            //No readable body

After Change


                        log.debug("Appending body to the response container (Current Size: {}) : \n{}", msg.readableBytes(), hexDump);

                        //Append the split-packet to the container
                        msg.readBytes(rconSplitPacket.body, msg.readableBytes());
                    } else {
                        log.debug("Found the end of the split-packet response. Last Two Bytes ({}, {}), Total Bytes Read: {}", msg.getByte(packetSize - 2), msg.getByte(packetSize - 1), totalBytesRead.get());
                        isSplitPacket.set(false);